#include <func.h>

#define MAXLINE 1024

int main(int argc, char* argv[])
{
    int rfd = open("fifo1", O_RDONLY);  /* 阻塞点 */
    if (rfd == -1) {
        perror("open()");
        exit(1);
    }

    int wfd = open("fifo2", O_WRONLY); /* 阻塞点 */
    if (wfd == -1) {
        perror("open()");
        exit(1);
    }
    // 全双工通信建立
    printf("Established\n");

    char recvline[MAXLINE];
    char sendline[MAXLINE];
    // 从键盘(stdin)接收数据
    while (fgets(sendline, MAXLINE, stdin)) {
        // 通过管道2发送给p2
        write(wfd, sendline, strlen(sendline) + 1);
        // 从fifo1管道1接收消息
        read(rfd, recvline, MAXLINE);
        // 写到屏幕(stdout)
        printf("From p2: %s", recvline);
    }

    return 0;
}

